package com.sxj.corejava.code02_jdbc;

import com.sxj.corejava.entity.User;

import java.sql.*;
import java.util.ArrayList;
import java.util.List;

/**
 * @author 石小俊
 * @date 2023年11月2023/11/28日 18:14
 */
public class Test01_基本操作 {

    public static void main(String[] args) {
//        User user = new User("alice","111111","13912345678","江苏-南京");
//        insertUser(user);
//        User user = new User(2,"tom","222222","13912345678","江苏-南京");
//        updateUser(user);
//        deleteById(2);
//        List<User> users = selectAll();
//        for(User user : users){
//            System.out.println(user);
//        }

        User user = selectById(1);
        System.out.println(user);

    }


    /**
     * 将参数指定的User对象的数据插入到数据库的t_user表中
     * 对象的属性值即为插入到数据库中的字段的值
     * 对象的属性与数据库字段一一对应
     * 类映射表
     * 属性映射字段
     * @param user
     */
    public static void insertUser(User user) {
        Connection conn = null;
        Statement st = null;
        try {
            // 1.注册驱动
            // 注册由数据库厂商所提供的驱动
            // 根据数据库类型、版本不同,驱动类所在的包名与类名也可能不同
            // 此处以MySQL为例
            // 通过Class.forName("包名.类名")进行注册
            // 注册MySQL5版本的驱动
            Class.forName("com.mysql.jdbc.Driver");
            // 注册MySQL5版本的驱动
            // Class.forName("com.mysql.cj.jdbc.Driver");

            // 2.获取连接
            // 连接到指定的数据库中,由数据库厂商提供了连接方式
            // 参数一:连接到数据库的url地址
                // 对于MySQL而言,其url地址的格式为 jdbc:mysql://mysql服务的ip地址:端口号/库名
                // 如果是本地MySQL,ip地址可以使用本机IP,也可以使用本地ip127.0.0.1或者localhost
                // 端口号默认为3306
                // 在操作中,可能存在Java访问数据库时的乱码问题
                // 为了解决乱码,MySQL5需要在库名后添加?useUnicode=true&characterEncoding=utf-8
                // MySQL8需要在库名后添加?characterEncoding=utf-8&serverTimezone=UTC
            // 参数二:数据库用户名
            // 参数三:数据库密码
            // conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/jdbc", "root", "");
            conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/jdbc?useUnicode=true&characterEncoding=utf-8", "root", "");

            // 3.获取状态集
            st = conn.createStatement();

            // 4.执行sql
            // 准备一个需要在数据库中执行的sql语句
            String sql = "insert into t_user(username,password,phone,address) values('" + user.getUsername() + "','" + user.getPassword() + "','" + user.getPhone() + "','" + user.getAddress() + "')";

            // 执行sql
            // 方法返回值为受到影响的数据的行数
            int rows = st.executeUpdate(sql);
            System.out.println("Query OK, " + rows + " rows affected");

            // 5.结果集映射
            // 如果是查询,需要对查询到的数据进行处理
            // 将数据库查询到的结果映射成Java对象
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            System.out.println("未找到驱动");
        } catch (SQLException e) {
            e.printStackTrace();
            System.out.println("连接数据库失败");
        } finally {
            // 6.释放资源
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                    System.out.println("释放连接出错");
                }
            }
            if (st != null) {
                try {
                    st.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    public static void updateUser(User user){
        Connection conn = null;
        Statement st = null;
        try {
            // 1.注册驱动
            // 注册由数据库厂商所提供的驱动
            // 根据数据库类型、版本不同,驱动类所在的包名与类名也可能不同
            // 此处以MySQL为例
            // 通过Class.forName("包名.类名")进行注册
            // 注册MySQL5版本的驱动
            Class.forName("com.mysql.jdbc.Driver");
            // 注册MySQL5版本的驱动
            // Class.forName("com.mysql.cj.jdbc.Driver");

            // 2.获取连接
            // 连接到指定的数据库中,由数据库厂商提供了连接方式
            // 参数一:连接到数据库的url地址
            // 对于MySQL而言,其url地址的格式为 jdbc:mysql://mysql服务的ip地址:端口号/库名
            // 如果是本地MySQL,ip地址可以使用本机IP,也可以使用本地ip127.0.0.1或者localhost
            // 端口号默认为3306
            // 在操作中,可能存在Java访问数据库时的乱码问题
            // 为了解决乱码,MySQL5需要在库名后添加?useUnicode=true&characterEncoding=utf-8
            // MySQL8需要在库名后添加?characterEncoding=utf-8&serverTimezone=UTC
            // 参数二:数据库用户名
            // 参数三:数据库密码
            // conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/jdbc", "root", "");
            conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/jdbc?useUnicode=true&characterEncoding=utf-8", "root", "");

            // 3.获取状态集
            st = conn.createStatement();

            // 4.执行sql
            // 准备一个需要在数据库中执行的sql语句
            String sql = "update t_user set username = '"+user.getUsername()+"',password = '"+user.getPassword()+"',phone = '"+user.getPhone()+"',address = '"+user.getAddress()+"' where id = "+user.getId()+"";

            // 执行sql
            // 方法返回值为受到影响的数据的行数
            int rows = st.executeUpdate(sql);
            System.out.println("Query OK, " + rows + " rows affected");

            // 5.结果集映射
            // 如果是查询,需要对查询到的数据进行处理
            // 将数据库查询到的结果映射成Java对象
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            System.out.println("未找到驱动");
        } catch (SQLException e) {
            e.printStackTrace();
            System.out.println("连接数据库失败");
        } finally {
            // 6.释放资源
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                    System.out.println("释放连接出错");
                }
            }
            if (st != null) {
                try {
                    st.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    public static void deleteById(Integer id){
        Connection conn = null;
        Statement st = null;
        try {
            // 1.注册驱动
            // 注册由数据库厂商所提供的驱动
            // 根据数据库类型、版本不同,驱动类所在的包名与类名也可能不同
            // 此处以MySQL为例
            // 通过Class.forName("包名.类名")进行注册
            // 注册MySQL5版本的驱动
            Class.forName("com.mysql.jdbc.Driver");
            // 注册MySQL5版本的驱动
            // Class.forName("com.mysql.cj.jdbc.Driver");

            // 2.获取连接
            // 连接到指定的数据库中,由数据库厂商提供了连接方式
            // 参数一:连接到数据库的url地址
            // 对于MySQL而言,其url地址的格式为 jdbc:mysql://mysql服务的ip地址:端口号/库名
            // 如果是本地MySQL,ip地址可以使用本机IP,也可以使用本地ip127.0.0.1或者localhost
            // 端口号默认为3306
            // 在操作中,可能存在Java访问数据库时的乱码问题
            // 为了解决乱码,MySQL5需要在库名后添加?useUnicode=true&characterEncoding=utf-8
            // MySQL8需要在库名后添加?characterEncoding=utf-8&serverTimezone=UTC
            // 参数二:数据库用户名
            // 参数三:数据库密码
            // conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/jdbc", "root", "");
            conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/jdbc?useUnicode=true&characterEncoding=utf-8", "root", "");

            // 3.获取状态集
            st = conn.createStatement();

            // 4.执行sql
            // 准备一个需要在数据库中执行的sql语句
            String sql = "delete from t_user where id = "+id+"";

            // 执行sql
            // 方法返回值为受到影响的数据的行数
            int rows = st.executeUpdate(sql);
            System.out.println("Query OK, " + rows + " rows affected");

            // 5.结果集映射
            // 如果是查询,需要对查询到的数据进行处理
            // 将数据库查询到的结果映射成Java对象
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            System.out.println("未找到驱动");
        } catch (SQLException e) {
            e.printStackTrace();
            System.out.println("连接数据库失败");
        } finally {
            // 6.释放资源
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                    System.out.println("释放连接出错");
                }
            }
            if (st != null) {
                try {
                    st.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    public static List<User> selectAll(){
        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;
        List<User> users = new ArrayList<>();
        try {
            // 1.注册驱动
            // 注册由数据库厂商所提供的驱动
            // 根据数据库类型、版本不同,驱动类所在的包名与类名也可能不同
            // 此处以MySQL为例
            // 通过Class.forName("包名.类名")进行注册
            // 注册MySQL5版本的驱动
            Class.forName("com.mysql.jdbc.Driver");
            // 注册MySQL5版本的驱动
            // Class.forName("com.mysql.cj.jdbc.Driver");

            // 2.获取连接
            // 连接到指定的数据库中,由数据库厂商提供了连接方式
            // 参数一:连接到数据库的url地址
            // 对于MySQL而言,其url地址的格式为 jdbc:mysql://mysql服务的ip地址:端口号/库名
            // 如果是本地MySQL,ip地址可以使用本机IP,也可以使用本地ip127.0.0.1或者localhost
            // 端口号默认为3306
            // 在操作中,可能存在Java访问数据库时的乱码问题
            // 为了解决乱码,MySQL5需要在库名后添加?useUnicode=true&characterEncoding=utf-8
            // MySQL8需要在库名后添加?characterEncoding=utf-8&serverTimezone=UTC
            // 参数二:数据库用户名
            // 参数三:数据库密码
            // conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/jdbc", "root", "");
            conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/jdbc?useUnicode=true&characterEncoding=utf-8", "root", "");

            // 3.获取状态集
            st = conn.createStatement();

            // 4.执行sql
            // 准备一个需要在数据库中执行的sql语句
            String sql = "select id,username,password,phone,address from t_user";

            // 执行sql
            // 此时的方法返回值是表示查询到的所有数据
            // 在此处,返回的是查询到的所有数据,存在多行数据
            // 需要将查询结果中的数据映射成Java的数据
            // 在结果集中,每一行数据映射成一个Java对象
            // 在读取结果集的时候,可以按行进行读取
            rs = st.executeQuery(sql);

            // 5.结果集映射
            // 如果是查询,需要对查询到的数据进行处理
            // 将数据库查询到的结果映射成Java对象
            // next():将光标移动到下一行
            // ResultSet光标最初位于第一行之前; 第一次调用方法next使第一行成为当前行; 第二个调用使第二行成为当前行，依此类推
            // 其返回值是布尔类型,值为true表示存在下一行,值为false表示不存在下一行
            // 只要存在下一行,每一行数据都映射成一个Java对象
            while(rs.next()){
                // 进入循环之后,我们可以读取光标所在的这一行数据
                // 将这一行数据映射成一个对应的Java对象
                User user = new User();
                // 可以通过getXxx(int index)与getXxx(String label)两种方法读取对应列的数据
                // Xxx部分的值是根据当前值的类型不同选择不同的方法
                // index:表示第几列
                // label:表示列名,建议使用方式
                // 读取第一列的数据
                user.setId(rs.getInt(1));
                user.setUsername(rs.getString("username"));
                user.setPassword(rs.getString("password"));
                user.setPhone(rs.getString("phone"));
                user.setAddress(rs.getString("address"));
                // 在查询时,查询到的数据可能不止一个对象
                // 因此,可以创建一个对象集合来接收
                // 集合中的每一个对象的值对应查询结果中的一行数据
                // 光标每移动一次,映射一行数据,并将映射好的数据添加到对象集合中
                users.add(user);
            }

        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            System.out.println("未找到驱动");
        } catch (SQLException e) {
            e.printStackTrace();
            System.out.println("连接数据库失败");
        } finally {
            // 6.释放资源
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                    System.out.println("释放连接出错");
                }
            }
            if (st != null) {
                try {
                    st.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(rs != null){
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
        return users;
    }

    public static User selectById(Integer id){
        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;
        User user = null;
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/jdbc?useUnicode=true&characterEncoding=utf-8", "root", "");
            st = conn.createStatement();
            String sql = "select id,username,password,phone,address from t_user where id = "+id+"";

            rs = st.executeQuery(sql);
            if(rs.next()){
                user = new User();
                user.setId(rs.getInt("id"));
                user.setUsername(rs.getString("username"));
                user.setPassword(rs.getString("password"));
                user.setPhone(rs.getString("phone"));
                user.setAddress(rs.getString("address"));
            }

        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            System.out.println("未找到驱动");
        } catch (SQLException e) {
            e.printStackTrace();
            System.out.println("连接数据库失败");
        } finally {
            // 6.释放资源
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                    System.out.println("释放连接出错");
                }
            }
            if (st != null) {
                try {
                    st.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(rs != null){
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
        return user;
    }
}
